RainLoop / rainloop-webmail

import _ from '_';

import $ from '$';

import ko from 'ko';

import {MessagePriority, SignedVerifyStatus} from 'Common/Enums';

import {

	pInt, inArray, isArray, isUnd, trim,

	previewMessage, windowResize, friendlySize, isNonEmptyArray

} from 'Common/Utils';

import {$win} from 'Common/Globals';

import {messageViewLink, messageDownloadLink} from 'Common/Links';

import {emailArrayFromJson, emailArrayToStringClear, emailArrayToString, replyHelper} from 'Helper/Message';

import {AttachmentModel, staticCombinedIconClass} from 'Model/Attachment';

import {AbstractModel} from 'Knoin/AbstractModel';

class MessageModel extends AbstractModel

{

	/**

	 * @static

	 * @returns {?MessageModel}

	 */

	static newInstanceFromJson(json) {

		const oMessageModel = new MessageModel();

		return oMessageModel.initByJson(json) ? oMessageModel : null;

	}

	clear() {

		this.folderFullNameRaw = '';

		this.uid = '';

		this.hash = '';

		this.requestHash = '';

		this.subject('');

		this.subjectPrefix('');

		this.subjectSuffix('');

		this.size(0);

		this.dateTimeStampInUTC(0);

		this.priority(MessagePriority.Normal);

		this.proxy = false;

		this.fromEmailString('');

		this.fromClearEmailString('');

		this.toEmailsString('');

		this.toClearEmailsString('');

		this.senderEmailsString('');

		this.senderClearEmailsString('');

		this.emails = [];

		this.from = [];

		this.to = [];

		this.cc = [];

		this.bcc = [];

		this.replyTo = [];

		this.deliveredTo = [];

		this.unsubsribeLinks = [];

		this.newForAnimation(false);

		this.deleted(false);

		this.deletedMark(false);

		this.unseen(false);

		this.flagged(false);

		this.answered(false);

		this.forwarded(false);

		this.isReadReceipt(false);

		this.selected(false);

		this.checked(false);

		this.hasAttachments(false);

		this.attachmentsSpecData([]);

		this.body = null;

		this.isHtml(false);

		this.hasImages(false);

		this.attachments([]);

		this.isPgpSigned(false);

		this.isPgpEncrypted(false);

		this.pgpSignedVerifyStatus(SignedVerifyStatus.None);

		this.pgpSignedVerifyUser('');

		this.priority(MessagePriority.Normal);

		this.readReceipt('');

		this.aDraftInfo = [];

		this.sMessageId = '';

		this.sInReplyTo = '';

		this.sReferences = '';

		this.threads([]);

		this.hasUnseenSubMessage(false);

		this.hasFlaggedSubMessage(false);

	}

	/**

	 * @param {Array} properties

	 * @returns {Array}

	 */

	getEmails(properties) {

		return _.compact(_.uniq(_.map(

			_.reduce(properties, (carry, property) => carry.concat(this[property]), []),

			(oItem) => (oItem ? oItem.email : '')

		)));

	}

	/**

	 * @returns {Array}

	 */

	getRecipientsEmails() {

		return this.getEmails(['to', 'cc']);

	}

	/**

	 * @returns {string}

	 */

	friendlySize() {

		return friendlySize(this.size());

	}

	computeSenderEmail() {

		const

			sentFolder = require('Stores/User/Folder').sentFolder(),

			draftFolder = require('Stores/User/Folder').draftFolder();

		this.senderEmailsString(this.folderFullNameRaw === sentFolder || this.folderFullNameRaw === draftFolder ?

			this.toEmailsString() : this.fromEmailString());

		this.senderClearEmailsString(this.folderFullNameRaw === sentFolder || this.folderFullNameRaw === draftFolder ?

			this.toClearEmailsString() : this.fromClearEmailString());

	}

	/**

	 * @param {AjaxJsonMessage} json

	 * @returns {boolean}

	 */

	initByJson(json) {

		let

			result = false,

		if (json && 'Object/Message' === json['@Object'])

		{

			priority = pInt(json.Priority);

			this.priority(-1 < inArray(priority, [MessagePriority.High, MessagePriority.Low]) ? priority : MessagePriority.Normal);

			this.folderFullNameRaw = json.Folder;

			this.uid = json.Uid;

			this.hash = json.Hash;

			this.requestHash = json.RequestHash;

			this.proxy = !!json.ExternalProxy;

			this.size(pInt(json.Size));

			this.from = emailArrayFromJson(json.From);

			this.to = emailArrayFromJson(json.To);

			this.cc = emailArrayFromJson(json.Cc);

			this.bcc = emailArrayFromJson(json.Bcc);

			this.replyTo = emailArrayFromJson(json.ReplyTo);

			this.deliveredTo = emailArrayFromJson(json.DeliveredTo);

			this.unsubsribeLinks = isNonEmptyArray(json.UnsubsribeLinks) ? json.UnsubsribeLinks : [];

			this.subject(json.Subject);

			if (isArray(json.SubjectParts))

			{

				this.subjectPrefix(json.SubjectParts[0]);

				this.subjectSuffix(json.SubjectParts[1]);

			}

			else

			{

				this.subjectPrefix('');

				this.subjectSuffix(this.subject());

			}

			this.dateTimeStampInUTC(pInt(json.DateTimeStampInUTC));

			this.hasAttachments(!!json.HasAttachments);

			this.attachmentsSpecData(isArray(json.AttachmentsSpecData) ? json.AttachmentsSpecData : []);

			this.fromEmailString(emailArrayToString(this.from, true));

			this.fromClearEmailString(emailArrayToStringClear(this.from));

			this.toEmailsString(emailArrayToString(this.to, true));

			this.toClearEmailsString(emailArrayToStringClear(this.to));

			this.threads(isArray(json.Threads) ? json.Threads : []);

			this.initFlagsByJson(json);

			this.computeSenderEmail();

			result = true;

		}

		return result;

	}

	/**

	 * @param {AjaxJsonMessage} json

	 * @returns {boolean}

	 */

	initUpdateByMessageJson(json) {

		let

			result = false,

		if (json && 'Object/Message' === json['@Object'])

		{

			priority = pInt(json.Priority);

			this.priority(-1 < inArray(priority, [MessagePriority.High, MessagePriority.Low]) ?

				priority : MessagePriority.Normal);

			this.aDraftInfo = json.DraftInfo;

			this.sMessageId = json.MessageId;

			this.sInReplyTo = json.InReplyTo;

			this.sReferences = json.References;

			this.proxy = !!json.ExternalProxy;

			if (require('Stores/User/Pgp').capaOpenPGP())

			{

				this.isPgpSigned(!!json.PgpSigned);

				this.isPgpEncrypted(!!json.PgpEncrypted);

			}

			this.hasAttachments(!!json.HasAttachments);

			this.attachmentsSpecData(isArray(json.AttachmentsSpecData) ? json.AttachmentsSpecData : []);

			this.foundedCIDs = isArray(json.FoundedCIDs) ? json.FoundedCIDs : [];

			this.attachments(this.initAttachmentsFromJson(json.Attachments));

			this.readReceipt(json.ReadReceipt || '');

			this.computeSenderEmail();

			result = true;

		}

		return result;

	}

	/**

	 * @returns {Array}

	 */

	initAttachmentsFromJson(json) {

		let

			index = 0,

			len = 0,

		const result = [];

		if (json && 'Collection/AttachmentCollection' === json['@Object'] && isNonEmptyArray(json['@Collection']))

		{

			for (index = 0, len = json['@Collection'].length; index < len; index++)

			{

				attachment = AttachmentModel.newInstanceFromJson(json['@Collection'][index]);

				if (attachment)

				{

					if ('' !== attachment.cidWithOutTags && 0 < this.foundedCIDs.length &&

						0 <= inArray(attachment.cidWithOutTags, this.foundedCIDs))

					{

						attachment.isLinked = true;

					}

					result.push(attachment);

				}

			}

		}

		return result;

	}

	/**

	 * @returns {boolean}

	 */

	hasUnsubsribeLinks() {

		return this.unsubsribeLinks && 0 < this.unsubsribeLinks.length;

	}

	/**

	 * @returns {string}

	 */

	getFirstUnsubsribeLink() {

		return this.unsubsribeLinks && 0 < this.unsubsribeLinks.length ? (this.unsubsribeLinks[0] || '') : '';

	}

	/**

	 * @param {AjaxJsonMessage} json

	 * @returns {boolean}

	 */

	initFlagsByJson(json) {

		let result = false;

		if (json && 'Object/Message' === json['@Object'])

		{

			this.unseen(!json.IsSeen);

			this.flagged(!!json.IsFlagged);

			this.answered(!!json.IsAnswered);

			this.forwarded(!!json.IsForwarded);

			this.isReadReceipt(!!json.IsReadReceipt);

			this.deletedMark(!!json.IsDeleted);

			result = true;

		}

		return result;

	}

	/**

	 * @param {boolean} friendlyView

	 * @param {boolean=} wrapWithLink = false

	 * @returns {string}

	 */

	fromToLine(friendlyView, wrapWithLink = false) {

		return emailArrayToString(this.from, friendlyView, wrapWithLink);

	}

	/**

	 * @returns {string}

	 */

	fromDkimData() {

		let result = ['none', ''];

		if (isNonEmptyArray(this.from) && 1 === this.from.length && this.from[0] && this.from[0].dkimStatus)

		{

			result = [this.from[0].dkimStatus, this.from[0].dkimValue || ''];

		}

		return result;

	}

	/**

	 * @param {boolean} friendlyView

	 * @param {boolean=} wrapWithLink = false

	 * @returns {string}

	 */

	toToLine(friendlyView, wrapWithLink = false) {

		return emailArrayToString(this.to, friendlyView, wrapWithLink);

	}

	/**

	 * @param {boolean} friendlyView

	 * @param {boolean=} wrapWithLink = false

	 * @returns {string}

	 */

	ccToLine(friendlyView, wrapWithLink = false) {

		return emailArrayToString(this.cc, friendlyView, wrapWithLink);

	}

	/**

	 * @param {boolean} friendlyView

	 * @param {boolean=} wrapWithLink = false

	 * @returns {string}

	 */

	bccToLine(friendlyView, wrapWithLink = false) {

		return emailArrayToString(this.bcc, friendlyView, wrapWithLink);

	}

	/**

	 * @param {boolean} friendlyView

	 * @param {boolean=} wrapWithLink = false

	 * @returns {string}

	 */

	replyToToLine(friendlyView, wrapWithLink = false) {

		return emailArrayToString(this.replyTo, friendlyView, wrapWithLink);

	}

	/**

	 * @return string

	 */

	lineAsCss() {

		const result = [];

		if (this.deleted())

		{

			result.push('deleted');

		}

		if (this.deletedMark())

		{

			result.push('deleted-mark');

		}

		if (this.selected())

		{

			result.push('selected');

		}

		if (this.checked())

		{

			result.push('checked');

		}

		if (this.flagged())

		{

			result.push('flagged');

		}

		if (this.unseen())

		{

			result.push('unseen');

		}

		if (this.answered())

		{

			result.push('answered');

		}

		if (this.forwarded())

		{

			result.push('forwarded');

		}

		if (this.focused())

		{

			result.push('focused');

		}

		if (this.isImportant())

		{

			result.push('important');

		}

		if (this.hasAttachments())

		{

			result.push('withAttachments');

		}

		if (this.newForAnimation())

		{

			result.push('new');

		}

		if ('' === this.subject())

		{

			result.push('emptySubject');

		}

//		if (1 < this.threadsLen())

//		{

//			result.push('hasChildrenMessage');

//		}

		if (this.hasUnseenSubMessage())

		{

			result.push('hasUnseenSubMessage');

		}

		if (this.hasFlaggedSubMessage())

		{

			result.push('hasFlaggedSubMessage');

		}

		return result.join(' ');

	}

	/**

	 * @returns {boolean}

	 */

	hasVisibleAttachments() {

		return !!_.find(this.attachments(), (item) => !item.isLinked);

	}

	/**

	 * @param {string} cid

	 * @returns {*}

	 */

	findAttachmentByCid(cid) {

		let result = null;

		const attachments = this.attachments();

		if (isNonEmptyArray(attachments))

		{

			cid = cid.replace(/^<+/, '').replace(/>+$/, '');

			result = _.find(attachments, (item) => cid === item.cidWithOutTags);

		}

		return result || null;

	}

	/**

	 * @param {string} contentLocation

	 * @returns {*}

	 */

	findAttachmentByContentLocation(contentLocation) {

		let result = null;

		const attachments = this.attachments();

		if (isNonEmptyArray(attachments))

		{

			result = _.find(attachments, (item) => contentLocation === item.contentLocation);

		}

		return result || null;

	}

	/**

	 * @returns {string}

	 */

	messageId() {

		return this.sMessageId;

	}

	/**

	 * @returns {string}

	 */

	inReplyTo() {

		return this.sInReplyTo;

	}

	/**

	 * @returns {string}

	 */

	references() {

		return this.sReferences;

	}

	/**

	 * @returns {string}

	 */

	fromAsSingleEmail() {

		return isArray(this.from) && this.from[0] ? this.from[0].email : '';

	}

	/**

	 * @returns {string}

	 */

	viewLink() {

		return messageViewLink(this.requestHash);

	}

	/**

	 * @returns {string}

	 */

	downloadLink() {

		return messageDownloadLink(this.requestHash);

	}

	/**

	 * @param {Object} excludeEmails

	 * @param {boolean=} last = false

	 * @returns {Array}

	 */

	replyEmails(excludeEmails, last = false) {

		const

			result = [],

			unic = isUnd(excludeEmails) ? {} : excludeEmails;

		replyHelper(this.replyTo, unic, result);

		if (0 === result.length)

		{

			replyHelper(this.from, unic, result);

		}

		if (0 === result.length && !last)

		{

			return this.replyEmails({}, true);

		}

		return result;

	}

	/**

	 * @param {Object} excludeEmails

	 * @param {boolean=} last = false

	 * @returns {Array.<Array>}

	 */

	replyAllEmails(excludeEmails, last = false) {

		const

			toResult = [],

			ccResult = [],

			unic = isUnd(excludeEmails) ? {} : excludeEmails;

		replyHelper(this.replyTo, unic, toResult);

		if (0 === toResult.length)

		{

			replyHelper(this.from, unic, toResult);

		}

		replyHelper(this.to, unic, toResult);

		replyHelper(this.cc, unic, ccResult);

		if (0 === toResult.length && !last)

		{

			data = this.replyAllEmails({}, true);

			return [data[0], ccResult];

		}

		return [toResult, ccResult];

	}

	/**

	 * @returns {string}

	 */

	textBodyToString() {

		return this.body ? this.body.html() : '';

	}

	/**

	 * @returns {string}

	 */

	attachmentsToStringLine() {

		const attachLines = _.map(this.attachments(), (item) => item.fileName + ' (' + item.friendlySize + ')');

		return attachLines && 0 < attachLines.length ? attachLines.join(', ') : '';

	}

	/**

	 * @param {boolean=} print = false

	 */

	viewPopupMessage(print = false) {

		this.showLazyExternalImagesInBody();

		previewMessage(this.subject(), this.body, this.isHtml(), print);

	}

	printMessage() {

		this.viewPopupMessage(true);

	}

	/**

	 * @returns {string}

	 */

	generateUid() {

		return this.folderFullNameRaw + '/' + this.uid;

	}

	/**

	 * @param {MessageModel} message

	 * @returns {MessageModel}

	 */

	populateByMessageListItem(message) {

		if (message)

		{

			this.folderFullNameRaw = message.folderFullNameRaw;

			this.uid = message.uid;

			this.hash = message.hash;

			this.requestHash = message.requestHash;

			this.subject(message.subject());

		}

		this.subjectPrefix(this.subjectPrefix());

		this.subjectSuffix(this.subjectSuffix());

		if (message)

		{

			this.size(message.size());

			this.dateTimeStampInUTC(message.dateTimeStampInUTC());

			this.priority(message.priority());

			this.proxy = message.proxy;

			this.fromEmailString(message.fromEmailString());

			this.fromClearEmailString(message.fromClearEmailString());

			this.toEmailsString(message.toEmailsString());

			this.toClearEmailsString(message.toClearEmailsString());

			this.emails = message.emails;

			this.from = message.from;

			this.to = message.to;

			this.cc = message.cc;

			this.bcc = message.bcc;

			this.replyTo = message.replyTo;

			this.deliveredTo = message.deliveredTo;

			this.unsubsribeLinks = message.unsubsribeLinks;

			this.unseen(message.unseen());

			this.flagged(message.flagged());

			this.answered(message.answered());

			this.forwarded(message.forwarded());

			this.isReadReceipt(message.isReadReceipt());

			this.deletedMark(message.deletedMark());

			this.priority(message.priority());

			this.selected(message.selected());

			this.checked(message.checked());

			this.hasAttachments(message.hasAttachments());

			this.attachmentsSpecData(message.attachmentsSpecData());

		}

		this.body = null;

		this.aDraftInfo = [];

		this.sMessageId = '';

		this.sInReplyTo = '';

		this.sReferences = '';

		if (message)

		{

			this.threads(message.threads());

		}

		this.computeSenderEmail();

		return this;

	}

	showLazyExternalImagesInBody() {

		if (this.body)

		{

			$('.lazy.lazy-inited[data-original]', this.body).each(function() {

				$(this).attr('src', $(this).attr('data-original')).removeAttr('data-original');

			});

		}

	}

	showExternalImages(lazy = false) {

		if (this.body && this.body.data('rl-has-images'))

		{

			this.hasImages(false);

			this.body.data('rl-has-images', false);

			var sAttr = this.proxy ? 'data-x-additional-src' : 'data-x-src';

			$('[' + sAttr + ']', this.body).each(function() {

				if (lazy && $(this).is('img'))

				{

					$(this)

						.addClass('lazy')

						.attr('data-original', $(this).attr(sAttr))

						.removeAttr(sAttr);

				}

				else

				{

					$(this).attr('src', $(this).attr(sAttr)).removeAttr(sAttr);

				}

			});

			sAttr = this.proxy ? 'data-x-additional-style-url' : 'data-x-style-url';

			$('[' + sAttr + ']', this.body).each(function() {

				var sStyle = trim($(this).attr('style'));

				sStyle = '' === sStyle ? '' : (';' === sStyle.substr(-1) ? sStyle + ' ' : sStyle + '; ');

				$(this).attr('style', sStyle + $(this).attr(sAttr)).removeAttr(sAttr);

			});

			if (lazy)

			{

				$('img.lazy', this.body).addClass('lazy-inited').lazyload({

					'threshold': 400,

					'effect': 'fadeIn',

					'skip_invisible': false,

					'container': $('.RL-MailMessageView .messageView .messageItem .content')[0]

				});

				$win.resize();

			}

			windowResize(500);

		}

	}

	showInternalImages(lazy = false) {

		if (this.body && !this.body.data('rl-init-internal-images'))

		{

			this.body.data('rl-init-internal-images', true);

			var self = this;

			$('[data-x-src-cid]', this.body).each(function() {

				const attachment = self.findAttachmentByCid($(this).attr('data-x-src-cid'));

				if (attachment && attachment.download)

				{

					if (lazy && $(this).is('img'))

					{

						$(this)

							.addClass('lazy')

							.attr('data-original', attachment.linkPreview());

					}

					else

					{

						$(this).attr('src', attachment.linkPreview());

					}

				}

			});

			$('[data-x-src-location]', this.body).each(function() {

				let attachment = self.findAttachmentByContentLocation($(this).attr('data-x-src-location'));

				if (!attachment)

				{

					attachment = self.findAttachmentByCid($(this).attr('data-x-src-location'));

				}

				if (attachment && attachment.download)

				{

					if (lazy && $(this).is('img'))

					{

						$(this)

							.addClass('lazy')

							.attr('data-original', attachment.linkPreview());

					}

					else

					{

						$(this).attr('src', attachment.linkPreview());

					}

				}

			});

			$('[data-x-style-cid]', this.body).each(function() {

				let

					style = '',

					name = '';

				const attachment = self.findAttachmentByCid($(this).attr('data-x-style-cid'));

				if (attachment && attachment.linkPreview)

				{

					name = $(this).attr('data-x-style-cid-name');

					if ('' !== name)

					{

						style = trim($(this).attr('style'));

						style = '' === style ? '' : (';' === style.substr(-1) ? style + ' ' : style + '; ');

						$(this).attr('style', style + name + ': url(\'' + attachment.linkPreview() + '\')');

					}

				}

			});

			if (lazy)

			{

				(function($oImg, oContainer) {

					_.delay(() => {

						$oImg.addClass('lazy-inited').lazyload({

							'threshold': 400,

							'effect': 'fadeIn',

							'skip_invisible': false,

							'container': oContainer

						});

					}, 300);

				}($('img.lazy', self.body), $('.RL-MailMessageView .messageView .messageItem .content')[0]));

			}

			windowResize(500);

		}

	}

	storeDataInDom() {

		if (this.body)

		{

			this.body.data('rl-is-html', !!this.isHtml());

			this.body.data('rl-has-images', !!this.hasImages());

		}

	}

	fetchDataFromDom() {

		if (this.body)

		{

			this.isHtml(!!this.body.data('rl-is-html'));

			this.hasImages(!!this.body.data('rl-has-images'));

		}

	}

	replacePlaneTextBody(plain) {

		if (this.body)

		{

			this.body.html(plain).addClass('b-text-part plain');

		}

	}

	/**

	 * @returns {string}

	 */

	flagHash() {

		return [this.deleted(), this.deletedMark(), this.unseen(), this.flagged(), this.answered(), this.forwarded(), this.isReadReceipt()].join(',');

	}

}

export {MessageModel, MessageModel as default};